package com.atguigu.flink.streamx;

import com.streamxhub.streamx.flink.core.TableContext;
import com.streamxhub.streamx.flink.core.TableEnvConfig;

/**
 * TODO
 *
 * @author cjp
 * @version 1.0
 */
public class StreamXSqlDemo {
    public static void main(String[] args) {

        TableEnvConfig tableEnvConfig = new TableEnvConfig(args, null);
        TableContext tableContext = new TableContext(tableEnvConfig);

        tableContext.sql("first");

    }
}
